package org.dromara.system.service.impl;

import jakarta.annotation.Resource;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.dromara.system.config.core.RedisMQSender;
import org.dromara.system.domain.ReceiveDealRecordsReqDTO;
import org.dromara.system.enums.RedisMQConstant;
import org.dromara.system.service.TradingService;
import org.springframework.stereotype.Service;

@Slf4j
@RequiredArgsConstructor
@Service
public class TradingServiceImpl implements TradingService {

    @Resource
    private RedisMQSender redisMQSender;


    @Override
    public Boolean kytTrading(ReceiveDealRecordsReqDTO receiveDealRecords) {
        redisMQSender.send(RedisMQConstant.TEST_QUEUE,receiveDealRecords);
        return Boolean.TRUE;
    }


}
